#ifndef MESSAGE_QUEUE
#define MESSAGE_QUEUE

#include <boost/interprocess/ipc/message_queue.hpp>


class CMessageQueue
{
public:

	CMessageQueue();
	~CMessageQueue();
	bool Create(const char* name, unsigned msg_num, unsigned msg_size);
	bool Open(const char* name);
	
	bool Send(const char *buf, unsigned len);
	bool TryRecv(char* buf, unsigned buf_len , unsigned &len);
private:

	boost::interprocess::message_queue *m_mq;
};

#endif